package com.itheima.kafka.boot.config.stream;

/**
 * 流数据的监听消费者实现的接口类，系统自动会通过
 * KafkaStreamListenerFactory类扫描项目中实现该接口的类
 * 并注册为流数据的消费端
 *
 * 其中泛型可是KStream或KTable
 * @param <T>
 */
public interface KafkaStreamListener<T> {

    // 监听的类型   接收待处理消息 from 源
    String listenerTopic();
    // 发送处理之后结果发送的类  to 目的地 topic
    String sendTopic();
    // 对象处理逻辑  // 流式处理
    T getService(T stream);

}
